wget --no-check-certificate --quiet \
--method POST \
--timeout=0 \
--header 'Accept: multipart/mixed;subscriptionSpec="1.0", application/json' \
--header 'Content-Type: application/json' \
--body-data '{"query":"subscription { countEmp2(max: 6, intervalMilliseconds: 1000) }"}' \
-O - 'http://localhost:3003/graphql'

curl -L 'http://localhost:3003/graphql' -H 'Accept: multipart/mixed;subscriptionSpec="1.0", application/json' -H 'Content-Type: application/json' -d '{"query":"subscription { countEmp2(max: 3, intervalMilliseconds: 500) }"}'

const { ApolloClient, InMemoryCache, HttpLink} = require('@apollo/client');
const gql = require('graphql-tag');

// Define your subscription query
const SUBSCRIPTION_QUERY = `
  subscription Test {
    countEmp2(max: 4, intervalMilliseconds: 1000)
  }
`;

// HTTP link for queries and mutations
const httpLink = new HttpLink({
  uri: 'http://localhost:3003/graphql',
  headers: {
    Accept: 'multipart/mixed;subscriptionSpec="1.0", application/json',
  },
});

// Create the Apollo Client
const client = new ApolloClient({
  link: httpLink,
  cache: new InMemoryCache(),
});

// Execute the subscription
const testSubscription = () => {
  const observable = client.subscribe({
    query: gql(SUBSCRIPTION_QUERY),
  });

  // Listen for incoming data
  observable.subscribe({
    next(data) {
      console.log('Subscription data:', data);
    },
    error(err) {
      if (err?.message === 'internal system error') {
        console.log("system error, ignore")
      } else {
        console.error('Subscription error:', err);
      }
    },
    complete() {
      console.log('Subscription completed');
    },
  });
};

// Start the test
console.log("hello world")
testSubscription();